package com.yifeng.repo.controller.rocketmq.message.client;

import org.apache.rocketmq.client.consumer.AllocateMessageQueueStrategy;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.remoting.RPCHook;

import java.util.List;

/**
 * Created by daibing on 2024/4/12.
 */
public class DefaultMQPushConsumerExt extends DefaultMQPushConsumer {

    public DefaultMQPushConsumerExt(String consumerGroup, RPCHook rpcHook, AllocateMessageQueueStrategy allocateMessageQueueStrategy) {
        super(consumerGroup, rpcHook, allocateMessageQueueStrategy);
    }

    public List<String> findConsumerIdList(String topic, String group) {
        return super.defaultMQPushConsumerImpl.getmQClientFactory().findConsumerIdList(topic, group);
    }

}
